home *** CD-ROM | disk | FTP | other *** search
/ Language/OS - Multiplatform Resource Library / LANGUAGE OS.iso / cpp_libs / nihcl-30.lha / nihcl-3.0 / test / stackproc.c < prev    next >
C/C++ Source or Header  |  1990-05-19  |  2KB  |  86 lines
  1. /* Test class StackProc
  2.  
  3.     THIS SOFTWARE FITS THE DESCRIPTION IN THE U.S. COPYRIGHT ACT OF A
  4.     "UNITED STATES GOVERNMENT WORK".  IT WAS WRITTEN AS A PART OF THE
  5.     AUTHOR'S OFFICIAL DUTIES AS A GOVERNMENT EMPLOYEE.  THIS MEANS IT
  6.     CANNOT BE COPYRIGHTED.  THIS SOFTWARE IS FREELY AVAILABLE TO THE
  7.     PUBLIC FOR USE WITHOUT A COPYRIGHT NOTICE, AND THERE ARE NO
  8.     RESTRICTIONS ON ITS USE, NOW OR SUBSEQUENTLY.
  9.  
  10. Author:
  11.     K. E. Gorlen
  12.     Bg. 12A, Rm. 2033
  13.     Computer Systems Laboratory
  14.     Division of Computer Research and Technology
  15.     National Institutes of Health
  16.     Bethesda, Maryland 20892
  17.     Phone: (301) 496-1111
  18.     uucp: uunet!nih-csl!kgorlen
  19.     Internet:kgorlen@alw.nih.gov
  20.  
  21. Function:
  22.     
  23. Modification History:
  24.     
  25. $Log:    stackproc.c,v $
  26.  * Revision 3.0  90/05/20  00:30:00  kgorlen
  27.  * Release for 1st edition.
  28.  * 
  29. */
  30. static char rcsid[] = "$Header: /afs/alw.nih.gov/unix/sun4_40c/usr/local/src/nihcl-3.0/share/test/RCS/stackproc.c,v 3.0 90/05/20 00:30:00 kgorlen Rel $";
  31.  
  32. #include "StackProc.h"
  33. #include "SharedQueue.h"
  34. #include "Scheduler.h"
  35. #include "String.h"
  36.  
  37. class TestStackProc : public StackProc {
  38. protected:
  39.     TestStackProc(const char* name, stackTy* bottom, int pri, SharedQueue& in, SharedQueue& out);
  40. public:
  41.     static TestStackProc* create(const char* name, int pri, SharedQueue& in, SharedQueue& out);
  42. };
  43.  
  44. TestStackProc::TestStackProc(const char* pname, stackTy* bottom, int pri, SharedQueue& in, SharedQueue& out)
  45.     : StackProc(pname,bottom,pri)
  46. {
  47.     if (FORK()) return;
  48.     while (YES) {
  49.         Object* msg = in.next();
  50.         cout << "process " << name() << " received " << *msg << endl;
  51.         out.nextPut(*msg);
  52.         cout << "process " << name() << " sent " << *msg << endl;
  53.     }
  54. }
  55.  
  56. TestStackProc* TestStackProc::create(const char* name, int pri, SharedQueue& in, SharedQueue& out)
  57. {
  58. #ifndef NESTED_TYPES
  59.     auto stackTy bottom;
  60. #else
  61.     auto Process::stackTy bottom;
  62. #endif
  63.     return new TestStackProc(name, &bottom, pri, in, out);
  64. }
  65.  
  66. main(int /* argc */, char** /* argv */)
  67. {
  68.     MAIN_PROCESS(0);
  69.     SharedQueue* q0 = new SharedQueue(2);
  70.     SharedQueue* qin = q0;
  71.     SharedQueue* qout;
  72.     for (int i=1; i <= MAXPRIORITY; i++) {
  73.         String pname = "P";
  74.         pname &= (char)('0'+i);
  75.         qout = new SharedQueue(2);
  76.         TestStackProc::create(pname,i,*qin,*qout);
  77.         qin = qout;
  78.     }
  79.     String& msg = *new String("THE MESSAGE");
  80.     Scheduler::dumpOn(cerr);
  81.     q0->dumpOn(cerr);
  82.     Scheduler::yield();
  83.     q0->nextPut(msg);
  84.     cout << *qout->next() << endl;
  85. }
  86.